e3317f2c6b493fe1b520daa221a6f19c4393266b,src/test/java/org/elasticsearch/recovery/RecoveryWhileUnderLoadTests.java,RecoveryWhileUnderLoadTests,recoverWhileUnderLoadAllocateBackupsRelocatePrimariesTest,#,147

Before Change



            logger.info("--> waiting for 4000 docs to be indexed ...");
            waitForDocs(4000);
            logger.info("--> 4000 docs indexed");
            logger.info("--> allow 4 nodes for index [test] ...");
            allowNodes("test", 4);

            logger.info("--> waiting for GREEN health status ...");
            assertThat(client().admin().cluster().prepareHealth().setWaitForEvents(Priority.LANGUID).setTimeout("1m").setWaitForGreenStatus().setWaitForNodes(">=4").execute().actionGet().isTimedOut(), equalTo(false));


            logger.info("--> waiting for 15000 docs to be indexed ...");
            waitForDocs(15000);
            logger.info("--> 15000 docs indexed");

            stop.set(true);
            stopLatch.await();

After Change


            };
            writers[i].start();
        }
        final int totalNumDocs = scaledRandomIntBetween(200, 20000);
        int waitFor = totalNumDocs / 3;
        try {
            logger.info("--> waiting for {} docs to be indexed ...", waitFor);
            waitForDocs(waitFor);
            logger.info("--> {} docs indexed",  waitFor);

            logger.info("--> flushing the index ....");
            // now flush, just to make sure we have some data in the index, not just translog
            client().admin().indices().prepareFlush().execute().actionGet();

            waitFor += totalNumDocs / 3;
            logger.info("--> waiting for {} docs to be indexed ...", waitFor);
            waitForDocs(waitFor);
            logger.info("--> {} docs indexed",  waitFor);
            logger.info("--> allow 4 nodes for index [test] ...");
            allowNodes("test", 4);

            logger.info("--> waiting for GREEN health status ...");
            assertThat(client().admin().cluster().prepareHealth().setWaitForEvents(Priority.LANGUID).setTimeout("1m").setWaitForGreenStatus().setWaitForNodes(">=4").execute().actionGet().isTimedOut(), equalTo(false));


            logger.info("--> waiting for {} docs to be indexed ...", totalNumDocs);
            waitForDocs(totalNumDocs);
            logger.info("--> {} docs indexed", totalNumDocs);

            stop.set(true);